package data

import "go_private_im/internal/logic/biz"

func (l *LogicRepo) CreateRoomMsg(roomMsg *biz.RoomMsg) error  {
	if err := l.data.Db.Table("room_msg").Create(roomMsg).Error; err != nil {
		return err
	}
	return nil
}
func (l *LogicRepo) CreateRoomMsgs(roomMsg []*biz.RoomMsg) error  {
	if err := l.data.Db.Table("room_msg").Create(roomMsg).Error; err != nil {
		return err
	}
	return nil
}

func (l *LogicRepo) GetRoomMsgs(roomId string) (roomMsg []*biz.RoomMsg,err error) {
	if err = l.data.Db.Table("room_msg").Where("room_id = ?",roomId).Find(&roomMsg).Error; err != nil {
		return
	}
	return
}